BidirectionalStream

abstract fun cancel(): Unit

Anuluje strumień. Można wywołać w dowolnym momencie po wywołaniu start. Gdy anulowanie zostanie zakończone i nie będą już wywoływane żadne metody wywołania zwrotnego, zostanie wywołana funkcja onCanceled(). Jeśli strumień został zakończony lub nie został uruchomiony, wywołanie cancel() nie przyniesie żadnego efektu, a funkcja onCanceled() nie zostanie wywołana. Jeśli Executor przekazany podczas tworzenia BidirectionalStream wykonuje zadania w jednym wątku, a cancel() jest wywoływana w tym wątku, po wywołaniu cancel() nie zostaną wywołane żadne metody odbiornika (oprócz onCanceled()). W przeciwnym razie po zakończeniu cancel() można wywołać co najwyżej 1 metodę wywołania zwrotnego.

abstract fun flush(): Unit

Opróżnia oczekujące zapisy. Tej metody nie należy wywoływać przed onStreamReady(). W przypadku wcześniej opóźnionych wywołań write() po wysłaniu bufora zostanie wywołana odpowiednia funkcja onWriteCompleted().

abstract fun isDone(): Boolean

Zwraca wartość true, jeśli strumień został pomyślnie uruchomiony i jest już zamknięty (zakończony, anulowany lub nieudany).

abstract fun read(buffer: ByteBuffer!): Unit

Odczytuje dane ze strumienia do podanego bufora. Można ją wywołać co najwyżej raz w odpowiedzi na każde wywołanie metod onStreamReady()/ onResponseHeadersReceived() i onReadCompleted() w Callback. Każde wywołanie spowoduje wywołanie jednej z metod Callback – onReadCompleted() (jeśli dane zostaną odczytane) lub onFailed() (jeśli wystąpi błąd). Rozpoczyna się próba odczytania danych do buffer od pozycji buffer.position(). Odczytanych zostanie co najwyżej buffer.remaining() bajtów. Po wywołaniu onReadCompleted() pozycja buffer.position() zostanie zaktualizowana, aby wskazać, ile danych zostało odczytanych.

abstract fun start(): Unit

Uruchamia strumień. Wszystkie wywołania zwrotne są przekazywane do argumentu callback przekazanego do konstruktora BidirectionalStream.Builder. Należy wywołać tylko raz.

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

Dodaje dane do zapisu w strumieniu. Dane zostaną wysłane dopiero po wywołaniu flush(). Każde wywołanie spowoduje wywołanie jednej z metod Callback – onWriteCompleted() (jeśli dane zostaną wysłane) lub onFailed() (jeśli wystąpi błąd).

Rozpoczyna się próba zapisania danych z buffer od pozycji buffer.position(). Zapisanych zostanie buffer.remaining() bajtów. Funkcja onWriteCompleted() zostanie wywołana tylko wtedy, gdy zostanie zapisany cały ByteBuffer.