Searched defs:downstream (Results 1 – 7 of 7) sorted by relevance
32 final Subscriber<? super Integer> downstream; field in FlowableCharSequence.CharSequenceSubscription42 CharSequenceSubscription(Subscriber<? super Integer> downstream, CharSequence string) { in CharSequenceSubscription()
56 final Subscriber<? super String> downstream; field in FlowableSplit.SplitSubscriber85 SplitSubscriber(Subscriber<? super String> downstream, Pattern pattern, int bufferSize) { in SplitSubscriber()
210 scopedFlow { downstream -> in debounceInternal() method280 return scopedFlow { downstream -> in sample() method
28 struct contenc_writer *downstream; /* Downstream writer. */ member
973 struct contenc_writer *downstream) in new_unencoding_writer()
29 def __init__(self, transformation, downstream): argument
120 Channel *downstream; /* Downstream mux*/ member522 Channel *downstream) in permission_set_add()2728 channel_proxy_downstream(struct ssh *ssh, Channel *downstream)2885 Channel *downstream; local