Base (network_pool.Network_pool.Pool

Parameters

module Diff : Intf.Resource_pool_diff_intf

module BC : 
  BC_ext
    with type resource_pool_diff = Diff.t
     and type rejected_diff = Diff.rejected

module Msg : sig ... end

Signature

include Mina_net2.Sink.S_with_void
  with type msg := Msg.raw_msg * Msg.raw_callback

include Mina_net2.Sink.S with type msg := Msg.raw_msg * Msg.raw_callback

type t

val push : 
  t ->
  (Msg.raw_msg * Msg.raw_callback) ->
  unit Async_kernel.Deferred.t

val void : t

type unwrapped_t = Diff.verified Network_peer.Envelope.Incoming.t * BC.t

val create : 
  ?on_push:( unit -> unit Async_kernel.Deferred.t ) ->
  ?log_gossip_heard:bool ->
  wrap:( unwrapped_t -> 'wrapped_t ) ->
  unwrap:( 'wrapped_t -> unwrapped_t ) ->
  trace_label:string ->
  logger:Logger.t ->
  Diff.pool ->
  'wrapped_t Pipe_lib.Strict_pipe.Reader.t * t * Rate_limiter.t