BidirectionalStream

public abstract void cancel()

Annule le flux. Peut être appelé à tout moment après start. onCanceled() est appelé lorsque l'annulation est terminée et aucune autre méthode de rappel n'est appelée. Si le flux est terminé ou n'a pas démarré, l'appel de cancel() n'a aucun effet et onCanceled() n'est pas appelé. Si l'Executor transmis lors de la construction de BidirectionalStream exécute des tâches sur un seul thread et que cancel() est appelé sur ce thread, aucune méthode d'écouteur (à l'exception de onCanceled()) n'est appelée après l'appel de cancel(). Sinon, au maximum une méthode de rappel peut être appelée une fois cancel() terminé.

public abstract void flush()

Vide les écritures en attente. Cette méthode ne doit pas être appelée avant onStreamReady(). Pour les write() précédemment retardés, un onWriteCompleted() correspondant est appelé lorsque le tampon est envoyé.

public abstract boolean isDone()

Renvoie true si le flux a été démarré et est maintenant terminé (réussi, annulé ou échoué).

public abstract void read(ByteBuffer buffer)

Lit les données du flux dans le tampon fourni. Ne peut être appelé qu'une seule fois au maximum en réponse à chaque appel des méthodes onStreamReady()/ onResponseHeadersReceived() et onReadCompleted() du Callback. Chaque appel entraîne l'appel de l'une des méthodes onReadCompleted() du Callback si des données sont lues, ou de sa méthode onFailed() en cas d'erreur. Une tentative de lecture des données dans buffer à partir de buffer.position() est lancée. Au maximum, buffer.remaining() octets sont lus. buffer.position() est mis à jour lors de l'appel de onReadCompleted() pour indiquer la quantité de données lues.

public abstract void start()

Démarre le flux. Tous les rappels sont envoyés à l'argument callback transmis au constructeur de BidirectionalStream.Builder. Ne doit être appelé qu'une seule fois.

public abstract void write(ByteBuffer buffer, boolean endOfStream)

Ajoute des données à écrire dans le flux. Les données ne sont envoyées qu'après l'appel de flush(). Chaque appel entraîne l'appel de l'une des méthodes onWriteCompleted() du Callback si des données sont envoyées, ou de sa méthode onFailed() en cas d'erreur.

Une tentative d'écriture des données à partir de buffer à partir de buffer.position() est lancée. buffer.remaining() octets sont écrits. onWriteCompleted() n'est appelé que lorsque le ByteBuffer complet est écrit.