BidirectionalStream

abstract fun cancel(): Unit

Annulla lo stream. Può essere chiamato in qualsiasi momento dopo start. onCanceled() verrà richiamato al termine dell'annullamento e non verranno richiamati altri metodi di callback. Se lo stream è stato completato o non è stato avviato, la chiamata a cancel() non ha alcun effetto e onCanceled() non verrà richiamato. Se l'Executor passato durante la costruzione di BidirectionalStream esegue le attività su un singolo thread e cancel() viene chiamato su quel thread, non verranno richiamati metodi di listener (oltre a onCanceled()) dopo la chiamata a cancel(). In caso contrario, dopo il completamento di cancel() può essere richiamato al massimo un metodo di callback.

abstract fun flush(): Unit

Esegue il flush delle scritture in attesa. Questo metodo non deve essere richiamato prima di onStreamReady(). Per le write()s ritardate in precedenza, verrà richiamato un onWriteCompleted() corrispondente quando il buffer viene inviato.

abstract fun isDone(): Boolean

Restituisce true se lo stream è stato avviato correttamente ed è stato completato (operazione riuscita, annullata o non riuscita).

abstract fun read(buffer: ByteBuffer!): Unit

Legge i dati dallo stream nel buffer fornito. Può essere chiamato al massimo una volta in risposta a ogni chiamata dei metodi onStreamReady()/ onResponseHeadersReceived() e onReadCompleted() di Callback. Ogni chiamata comporterà la chiamata del metodo onReadCompleted() di Callback se i dati vengono letti o del metodo onFailed() se si verifica un errore. Viene avviato un tentativo di leggere i dati in buffer a partire da buffer.position(). Vengono letti al massimo buffer.remaining() byte. buffer.position() viene aggiornato alla chiamata di onReadCompleted() per indicare la quantità di dati letti.

abstract fun start(): Unit

Avvia lo stream. Tutti i callback vengono inviati all'argomento callback passato al costruttore di BidirectionalStream.Builder. Deve essere chiamato una sola volta.

abstract fun write(buffer: ByteBuffer!, endOfStream: Boolean): Unit

Aggiunge i dati da scrivere nello stream. I dati verranno inviati solo dopo la chiamata a flush(). Ogni chiamata comporterà la chiamata del metodo onWriteCompleted() di Callback se i dati vengono inviati o del metodo onFailed() se si verifica un errore.

Viene avviato un tentativo di scrivere i dati da buffer a partire da buffer.position(). Verranno scritti buffer.remaining() byte. onWriteCompleted() verrà richiamato solo quando viene scritto l'intero ByteBuffer.