Editor de flujo para encadenar en java9

¿Cómo puedo obtener una cadena de Flow.Publisher<Byte> body? Solo quiero analizar la cadena desde Publisher.

Respuesta 1

Así es como puedes hacerlo con RxJava2 :

Flow.Publisher<Byte> bytes = ...;

Flowable.fromPublisher(
        FlowAdapters.toPublisher(
            bytes
        )
    ).toList()
        .map(byteList -> new String(convert(byteList)))
        .subscribe((String string) -> {
            System.out.println(string);
        });

convertir se define de la siguiente manera:

   static byte[] convert(List<Byte> list) {
        final byte[] bytes = new byte[list.size()];
        int idx = 0;
        for (byte b : list) {
            bytes[idx] = b;
            idx++;
        }
        return bytes;
    }
Respuesta: 2

¿Es posible encontrar una instancia de objeto utilizando un método público estático que espera un objeto de campo como parámetro? Eso es lo que busco: public class Foo {private Bar myObject; público estático ...

Tener el siguiente código scratch: public static void main (String [] args) lanza ExecutionException, InterruptedException {CompletableFuture <Void> process1 = CompletableFuture.runAsync (() - & ...

Estoy haciendo una tarea donde tengo que hacer dos cosas usando la exponenciación al cuadrar. Una es obtener el número de multiplicaciones y la otra es obtener el resultado real. Aquí hay algunos ejemplos: 2 ...

¿Alguien puede explicarme cómo configurar correctamente el HUB del servidor Selenium para IP y PUERTO específicos? Encontré este Bind selenium a una IP específica - ¿Posible? pero no estoy seguro de cuál es la IP correcta ya que ...