Subscriber using a io.zenoh.handlers.Handler for handling incoming samples.

Example using the default handler:

try (Session session = Zenoh.open(config)) {
    try (HandlerSubscriber<BlockingQueue<Optional<Sample>>> subscriber = session.declareSubscriber(keyExpr)) {
        BlockingQueue<Optional<Sample>> receiver = subscriber.getReceiver();
        assert receiver != null;
        while (true) {
            Optional<Sample> wrapper = receiver.take();
            if (wrapper.isEmpty()) {
                break;
            }
            System.out.println(wrapper.get());
        }
    }
}