BidirectionalStream

public abstract void cancel()

Anuluje strumień. Można wywołać w dowolnym momencie po wywołaniu start. onCanceled() zostanie wywołana, gdy anulowanie się zakończy, a żadne inne metody wywołania zwrotnego nie zostaną wywołane. Jeśli strumień został zakończony lub nie został uruchomiony, wywołanie cancel() nie ma ż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ływany 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.

public abstract void flush()

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().

public abstract boolean isDone()

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

public abstract void read(ByteBuffer buffer)

Odczytuje dane ze strumienia do podanego bufora. Można 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's onReadCompleted() w przypadku odczytania danych lub onFailed() w przypadku wystąpienia błędu. 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.

public abstract void start()

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

public abstract void write(ByteBuffer buffer, boolean endOfStream)

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's onWriteCompleted() w przypadku wysłania danych lub onFailed() w przypadku wystąpienia błędu.

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.