Local_sink (network_pool.Network_pool.Transaction_pool.Make.Local

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

type t

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

val void : t