Local_sink (network_pool.Network_pool.Network_pool_base.Make.Local

include Mina_net2.Sink.S
  with type msg :=
         Resource_pool.Diff.t
         * ( ([ `Broadcasted | `Not_broadcasted ]
              * Resource_pool.Diff.t
              * Resource_pool.Diff.rejected)
               Core_kernel.Or_error.t ->
         unit )

type t

val push : 
  t ->
  (Resource_pool.Diff.t
   * ( ([ `Broadcasted | `Not_broadcasted ]
        * Resource_pool.Diff.t
        * Resource_pool.Diff.rejected)
         Core_kernel.Or_error.t ->
   unit )) ->
  unit Async_kernel.Deferred.t

val void : t