if (data.endsWith(delimiter)) {
            String finalData = currentMessageBuilder.toString().trim();
            requests.onNext(new ClientRequest(socketChannel, finalData));
          }