Encode protobuf to iodata for better performance

lib/grpc/client/adapter.ex

@@ -14,7 +14,7 @@ defmodule GRPC.Client.Adapter do
 
   @callback disconnect(channel :: Channel.t()) :: {:ok, Channel.t()} | {:error, any()}
 
-  @callback send_request(stream :: Stream.t(), contents :: binary(), opts :: keyword()) ::
+  @callback send_request(stream :: Stream.t(), contents :: iodata(), opts :: keyword()) ::
               Stream.t()
 
   @doc """
@@ -36,7 +36,7 @@ defmodule GRPC.Client.Adapter do
    Opts:
       - :send_end_stream (optional) - ends the request stream
   """
-  @callback send_data(stream :: Stream.t(), message :: binary(), opts :: keyword()) :: Stream.t()
+  @callback send_data(stream :: Stream.t(), message :: iodata(), opts :: keyword()) :: Stream.t()
 
   @doc """
   Similarly to the option sent on `send_data/2` - :send_end_stream -

lib/grpc/codec.ex

@@ -5,7 +5,7 @@ defmodule GRPC.Codec do
 
   @doc ~s(Name is identity of the codec, which will be suffix after content-type "application/grpc+" such as "proto".)
   @callback name() :: String.t()
-  @callback encode(any) :: binary
+  @callback encode(any) :: iodata()
   @callback decode(any, module :: atom) :: any
 
   @doc """

lib/grpc/codec/proto.ex

@@ -5,8 +5,8 @@
     "proto"
   end
 
   def encode(%mod{} = struct) do
-    mod.encode(struct)
+    Protobuf.Encoder.encode_to_iodata(struct)
   end
 
   def decode(binary, module) do

lib/grpc/compressor.ex

@@ -1,5 +1,5 @@
 defmodule GRPC.Compressor do
   @callback name() :: String.t()
-  @callback compress(binary) :: binary
+  @callback compress(iodata()) :: binary
   @callback decompress(binary) :: binary
 end