writeSynResetLater(streamId, ErrorCode.PROTOCOL_ERROR)
        updateConnectionFlowControl(length.toLong())
        source.skip(length.toLong())
        return
      }
      dataStream.receiveData(source, length)
      if (inFinished) {
        dataStream.receiveHeaders(Headers.EMPTY, true)
      }
    }

    override fun headers(
      inFinished: Boolean,
      streamId: Int,

    }

    @Test
    public void test_dispatchEvent_eventData() {
        final AtomicReference<String> receivedData = new AtomicReference<>();
        final AtomicReference<String> receivedInstanceId = new AtomicReference<>();
        coordinatorHelper.addEventHandler("config_updated", event -> {
            receivedData.set(event.data);
            receivedInstanceId.set(event.instanceId);
        });