protected function getStreamingWrapperCreator()
    {
        return function ($connection, $callback) {
            return function ($state, $response) use ($connection, $callback) {
                \call_user_func($callback, $response, $connection, null);
            };
        };
    }