aboutsummaryrefslogtreecommitdiffstats
path: root/ethchain/transaction_pool.go
diff options
context:
space:
mode:
Diffstat (limited to 'ethchain/transaction_pool.go')
-rw-r--r--ethchain/transaction_pool.go19
1 files changed, 3 insertions, 16 deletions
diff --git a/ethchain/transaction_pool.go b/ethchain/transaction_pool.go
index 6c0282dc6..21ce8cdc1 100644
--- a/ethchain/transaction_pool.go
+++ b/ethchain/transaction_pool.go
@@ -133,7 +133,8 @@ func (pool *TxPool) ProcessTransaction(tx *Transaction, block *Block, toContract
log.Printf("[TXPL] Processed Tx %x\n", tx.Hash())
- pool.notifySubscribers(TxPost, tx)
+ // Notify all subscribers
+ pool.Ethereum.Reactor().Post("newTx:post", tx)
return
}
@@ -188,10 +189,7 @@ out:
pool.addTransaction(tx)
// Notify the subscribers
- pool.Ethereum.Reactor().Post("newTx", tx)
-
- // Notify the subscribers
- pool.notifySubscribers(TxPre, tx)
+ pool.Ethereum.Reactor().Post("newTx:pre", tx)
}
case <-pool.quit:
break out
@@ -252,14 +250,3 @@ func (pool *TxPool) Stop() {
log.Println("[TXP] Stopped")
}
-
-func (pool *TxPool) Subscribe(channel chan TxMsg) {
- pool.subscribers = append(pool.subscribers, channel)
-}
-
-func (pool *TxPool) notifySubscribers(ty TxMsgTy, tx *Transaction) {
- msg := TxMsg{Type: ty, Tx: tx}
- for _, subscriber := range pool.subscribers {
- subscriber <- msg
- }
-}