Skip to content
This repository was archived by the owner on Aug 26, 2022. It is now read-only.

Commit ef6b3bb

Browse files
authored
Merge branch 'master' into proposal/service-invocation
2 parents f3f0118 + 7e03cec commit ef6b3bb

File tree

2 files changed

+19
-14
lines changed

2 files changed

+19
-14
lines changed

apps/massa_proxy/lib/massa_proxy/runtime/grpc/protocol/action/stream_handler.ex

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,7 @@ defmodule MassaProxy.Runtime.Grpc.Protocol.Action.Stream.Handler do
6161
end
6262

6363
defp run_stream(client_stream, messages) do
64+
Logger.debug("Running client stream #{inspect(messages)}")
6465
Stream.map(messages, &send_stream_msg(client_stream, &1))
6566
end
6667

@@ -72,10 +73,12 @@ defmodule MassaProxy.Runtime.Grpc.Protocol.Action.Stream.Handler do
7273
end
7374

7475
defp send_stream_msg(client_stream, :halt) do
76+
Logger.debug("send_stream_msg :halt")
7577
GRPC.Stub.end_stream(client_stream)
7678
end
7779

7880
defp send_stream_msg(client_stream, msg) do
81+
Logger.debug("send_stream_msg #{inspect(msg)}")
7982
GRPC.Stub.send_request(client_stream, msg, [])
8083
end
8184
end

0 commit comments

Comments
 (0)