Flow.Subscriber (Java SE 9 & JDK 9 ) (original) (raw)

• Type Parameters:
  T - the subscribed item type
  All Known Subinterfaces:
  [Flow.Processor](../../../java/util/concurrent/Flow.Processor.html "interface in java.util.concurrent")<T,R>, [HttpResponse.BodyProcessor](../../../jdk/incubator/http/HttpResponse.BodyProcessor.html "interface in jdk.incubator.http")<T>
  Enclosing class:
  Flow

public static interface Flow.Subscriber
A receiver of messages. The methods in this interface are invoked in strict sequential order for each Flow.Subscription.

• • Method Summary

  All Methods Instance Methods Abstract Methods

  Modifier and Type	Method	Description
  void	onComplete​()	Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription.
  void	onError​(Throwable throwable)	Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription.
  void	onNext​(T item)	Method invoked with a Subscription's next item.
  void	onSubscribe​(Flow.Subscription subscription)	Method invoked prior to invoking any other Subscriber methods for the given Subscription.

• • Method Detail

     * #### onSubscribe  
     void onSubscribe​([Flow.Subscription](../../../java/util/concurrent/Flow.Subscription.html "interface in java.util.concurrent") subscription)  
     Method invoked prior to invoking any other Subscriber methods for the given Subscription. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription not to be established or to be cancelled.  
     Typically, implementations of this method invoke ` subscription.request` to enable receiving items.  
     Parameters:  
     `subscription` \- a new subscription  
     * #### onNext  
     void onNext​([T](../../../java/util/concurrent/Flow.Subscriber.html "type parameter in Flow.Subscriber") item)  
     Method invoked with a Subscription's next item. If this method throws an exception, resulting behavior is not guaranteed, but may cause the Subscription to be cancelled.  
     Parameters:  
     `item` \- the item  
     * #### onError  
     void onError​([Throwable](../../../java/lang/Throwable.html "class in java.lang") throwable)  
     Method invoked upon an unrecoverable error encountered by a Publisher or Subscription, after which no other Subscriber methods are invoked by the Subscription. If this method itself throws an exception, resulting behavior is undefined.  
     Parameters:  
     `throwable` \- the exception  
     * #### onComplete  
     void onComplete​()  
     Method invoked when it is known that no additional Subscriber method invocations will occur for a Subscription that is not already terminated by error, after which no other Subscriber methods are invoked by the Subscription. If this method throws an exception, resulting behavior is undefined.

Report a bug or suggest an enhancement
For further API reference and developer documentation see the Java SE Documentation, which contains more detailed, developer-targeted descriptions with conceptual overviews, definitions of terms, workarounds, and working code examples.
Java is a trademark or registered trademark of Oracle and/or its affiliates in the US and other countries.
Copyright © 1993, 2017, Oracle and/or its affiliates, 500 Oracle Parkway, Redwood Shores, CA 94065 USA.
All rights reserved. Use is subject to license terms and the documentation redistribution policy.