Cancel channel key on end of stream

seime · Jul 22, 2024 · b1b703a · b1b703a
1 parent e4adc6a
commit b1b703a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/no/seime/openhab/binding/esphome/internal/comm/ConnectionSelector.java b/src/main/java/no/seime/openhab/binding/esphome/internal/comm/ConnectionSelector.java
@@ -32,7 +32,7 @@ public void start() {
  logger.debug("Starting selector thread");
  while (keepRunning) {
  try {
- selector.select(1000);
+ selector.select(10000);
  // token representing the registration of a SelectableChannel with a Selector
  Set<SelectionKey> keys = selector.selectedKeys();
  logger.trace("Selected keys: {}", keys.size());
@@ -68,6 +68,7 @@ private void processKey(SelectionKey readyKey) {
  int read = channel.read(buffer);
  if (read == -1) {
  logger.debug("End of stream, closing");
+ channel.keyFor(selector).cancel();
  frameHelper.endOfStream();
  } else {
  if (read == READ_BUFFER_SIZE) {