aboutsummaryrefslogtreecommitdiff
path: root/src/nvim/msgpack_rpc
diff options
context:
space:
mode:
authorbfredl <bjorn.linse@gmail.com>2024-06-01 09:53:45 +0200
committerGitHub <noreply@github.com>2024-06-01 09:53:45 +0200
commit2008fe7b85a8c03cbff3ed51c5715ddf5cb555fd (patch)
tree3fe96507019c1d493f2e7f5212c35f063195b29d /src/nvim/msgpack_rpc
parent50f6d364c661b88a1edc5ffc8e284d1c0ff70810 (diff)
parentc13c50b752dca322a5ec77dea6188c9e3694549b (diff)
downloadrneovim-2008fe7b85a8c03cbff3ed51c5715ddf5cb555fd.tar.gz
rneovim-2008fe7b85a8c03cbff3ed51c5715ddf5cb555fd.tar.bz2
rneovim-2008fe7b85a8c03cbff3ed51c5715ddf5cb555fd.zip
Merge pull request #29106 from bfredl/rwstream
refactor(io): separate types for read and write streams
Diffstat (limited to 'src/nvim/msgpack_rpc')
-rw-r--r--src/nvim/msgpack_rpc/channel.c4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/nvim/msgpack_rpc/channel.c b/src/nvim/msgpack_rpc/channel.c
index 5737a0440f..98d5d8c6cb 100644
--- a/src/nvim/msgpack_rpc/channel.c
+++ b/src/nvim/msgpack_rpc/channel.c
@@ -89,7 +89,7 @@ void rpc_start(Channel *channel)
kv_init(rpc->call_stack);
if (channel->streamtype != kChannelStreamInternal) {
- Stream *out = channel_outstream(channel);
+ RStream *out = channel_outstream(channel);
#ifdef NVIM_LOG_DEBUG
Stream *in = channel_instream(channel);
DLOG("rpc ch %" PRIu64 " in-stream=%p out-stream=%p", channel->id,
@@ -202,7 +202,7 @@ Object rpc_send_call(uint64_t id, const char *method_name, Array args, ArenaMem
return frame.errored ? NIL : frame.result;
}
-static void receive_msgpack(Stream *stream, RBuffer *rbuf, size_t c, void *data, bool eof)
+static void receive_msgpack(RStream *stream, RBuffer *rbuf, size_t c, void *data, bool eof)
{
Channel *channel = data;
channel_incref(channel);