@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