luxlabs header browser preview


@class NSString;

@interface BPSPublisher : NSObject <BPSPublisher>

@property (readonly) unsigned long long hash;
@property (readonly) Class superclass;
@property (readonly, copy) NSString *description;
@property (readonly, copy) NSString *debugDescription;

- (id)startWithSubscriber:(id)a0;
- (BOOL)completed;
- (void)reset;
- (id)last;
- (id)upstreamPublishers;
- (void)subscribe:(id)a0;
- (id)multicast;
- (id)collect;
- (id)mergeWithOther:(id)a0;
- (id)drivableSinkWithBookmark:(id)a0 completion:(id /* block */)a1 shouldContinue:(id /* block */)a2;
- (id)mapWithTransform:(id /* block */)a0;
- (id)sinkWithBookmark:(id)a0 completion:(id /* block */)a1 receiveInput:(id /* block */)a2;
- (id)sinkWithCompletion:(id /* block */)a0 receiveInput:(id /* block */)a1;
- (id)sinkWithCompletion:(id /* block */)a0 shouldContinue:(id /* block */)a1;
- (id)filterWithIsIncluded:(id /* block */)a0;
- (id)flatMapWithTransform:(id /* block */)a0;
- (id)groupByKey:(id /* block */)a0;
- (id)reduceWithInitial:(id)a0 nextPartialResult:(id /* block */)a1;
- (id)scanWithInitial:(id)a0 nextPartialResult:(id /* block */)a1;
- (id)reduce:(id)a0;
- (id)bufferWithSize:(unsigned long long)a0 prefetch:(unsigned long long)a1 whenFull:(unsigned long long)a2;
- (id)combineLatestwithOther:(id)a0;
- (id)connectableSinkWithCompletion:(id /* block */)a0 shouldContinue:(id /* block */)a1;
- (id)correlateWithCurrent:(id)a0 comparator:(id /* block */)a1 correlateHandler:(id)a2;
- (id)debounceFor:(double)a0 getTimestamp:(id /* block */)a1;
- (id)handleEventsReceiveOutput:(id /* block */)a0 receiveCancel:(id /* block */)a1;
- (id)handleEventsReceiveSubscription:(id /* block */)a0 receiveOutput:(id /* block */)a1 receiveCompletion:(id /* block */)a2 receiveCancel:(id /* block */)a3 receiveRequest:(id /* block */)a4;
- (id)mergeWithOthers:(id)a0;
- (id)multicastCreateSubject:(id /* block */)a0;
- (id)multicastSubject:(id)a0;
- (id)orderedMergeWithOther:(id)a0 comparator:(id /* block */)a1;
- (id)orderedMergeWithOthers:(id)a0 comparator:(id /* block */)a1;
- (id)removeDuplicatesWithIsDuplicate:(id /* block */)a0;
- (id)sequenceWithSequence:(id)a0;
- (id)throttleFor:(double)a0 latest:(BOOL)a1 getTimestamp:(id /* block */)a2;
- (id)timerFor:(double)a0 getTimestamp:(id /* block */)a1;
- (id)windowByKey:(id /* block */)a0 assigner:(id)a1;
- (id)windowWithAssigner:(id)a0;
- (id)zipWithOther:(id)a0;
- (id)zipWithOthers:(id)a0;

@end