package Ġcom . rich ode mus . reader . common . google _ cloud _ storage _ adapter Ċ Ċ import Ġcom . rich ode mus . reader . events _ v 2 . Event Ċ Ċ /** Ċ Ġ* ĠMock Ġused Ġfor Ġtesting Ċ Ġ*/ Ċ class ĠIn Memory Event Store Ġ: ĠEvent Store Ġ{ ĊĠĠĠ Ġprivate Ġval Ġmessage Listeners Ġ= Ġmutable ListOf <( Event ) Ġ-> ĠUnit >() ĊĊĠĠĠ Ġoverride Ġfun Ġconsume ( message Listener : Ġ( Event ) Ġ-> ĠUnit ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . message Listeners . add ( message Listener ) ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġproduce ( event : ĠEvent ) Ġ{ ĊĠĠĠĠĠĠĠ Ġmessage Listeners . forEach Ġ{ Ġit ( event ) Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġoverride Ġfun Ġclose () Ġ{ ĊĠĠĠ Ġ} Ċ } Ċ