diff options
Diffstat (limited to 'core/nonblocking-application.go')
| -rw-r--r-- | core/nonblocking-application.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/core/nonblocking-application.go b/core/nonblocking-application.go index 2226eb0..98f92fc 100644 --- a/core/nonblocking-application.go +++ b/core/nonblocking-application.go @@ -154,6 +154,12 @@ func (app *nonBlockingApplication) DeliverBlock( app.addEvent(deliverBlockEvent{blockHash, timestamp}) } +// BlockProcessedChan returns a channel to receive the block hashes that have +// finished processing by the application. +func (app *nonBlockingApplication) BlockProcessedChan() <-chan types.WitnessResult { + return app.app.BlockProcessedChan() +} + // WitnessAckDeliver is called when a witness ack is created. func (app *nonBlockingApplication) WitnessAckDeliver(witnessAck *types.WitnessAck) { app.addEvent(witnessAckEvent{witnessAck}) |