BidirectionalStream

abstract fun cancel(): Unit

Cancela la transmisión. Se puede llamar en cualquier momento después de start. Se invocará onCanceled() cuando se complete la cancelación y no se invocarán más métodos de devolución de llamada. Si la transmisión se completó o no se inició, llamar a cancel() no tiene ningún efecto y no se invocará onCanceled(). Si el Executor que se pasó durante la construcción de BidirectionalStream ejecuta tareas en un solo subproceso y se llama a cancel() en ese subproceso, no se invocará ningún método de objeto de escucha (además de onCanceled()) después de que se llame a cancel(). De lo contrario, se puede invocar como máximo un método de devolución de llamada después de que se complete cancel().

abstract fun flush(): Unit

Vacía las escrituras pendientes. Este método no se debe invocar antes de onStreamReady(). Para las write()s retrasadas anteriormente, se invocará un onWriteCompleted() correspondiente cuando se envíe el búfer.

abstract fun isDone(): Boolean

Muestra true si la transmisión se inició correctamente y ahora está lista (se completó, se canceló o falló).

abstract fun read(buffer: ByteBuffer!): Unit

Lee datos de la transmisión en el búfer proporcionado. Solo se puede llamar como máximo una vez en respuesta a cada invocación de los métodos onStreamReady()/ onResponseHeadersReceived() y onReadCompleted() de Callback. Cada llamada generará una invocación de uno de los Callback's onReadCompleted() método si se leen datos o su onFailed() método si hay un error. Se inicia un intento de leer datos en buffer a partir de buffer.position(). Se leen como máximo buffer.remaining() bytes. buffer.position() se actualiza cuando se invoca onReadCompleted() para indicar cuántos datos se leyeron.

abstract fun start(): Unit

Inicia la transmisión. Todas las devoluciones de llamada van al argumento callback que se pasa al constructor de BidirectionalStream.Builder. Solo se debe llamar una vez.

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

Agrega datos para escribirlos en la transmisión. Los datos se enviarán solo después de que se llame a flush(). Cada llamada generará una invocación de uno de los métodos onWriteCompleted() de Callback si se envían datos o su método onFailed() si hay un error.

Se inicia un intento de escribir datos desde buffer a partir de buffer.position(). Se escribirán buffer.remaining() bytes. Se invocará onWriteCompleted() solo cuando se escriba el ByteBuffer completo.