@@ -234,7 +234,7 @@ func NewEventSystem(sys *FilterSystem, lightMode bool) *EventSystem {
234234	}
235235
236236	// Subscribe events 
237- 	m .txsSub  =  m .backend .SubscribeNewTxsEvent (m .txsCh )
237+ 	//  m.txsSub = m.backend.SubscribeNewTxsEvent(m.txsCh)
238238	m .logsSub  =  m .backend .SubscribeLogsEvent (m .logsCh )
239239	m .rmLogsSub  =  m .backend .SubscribeRemovedLogsEvent (m .rmLogsCh )
240240	m .chainSub  =  m .backend .SubscribeChainEvent (m .chainCh )
@@ -452,11 +452,11 @@ func (es *EventSystem) handleRemovedLogs(filters filterIndex, ev core.RemovedLog
452452	}
453453}
454454
455- func  (es  * EventSystem ) handleTxsEvent (filters  filterIndex , ev  core.NewTxsEvent ) {
456- 	for  _ , f  :=  range  filters [PendingTransactionsSubscription ] {
457- 		f .txs  <-  ev .Txs 
458- 	}
459- }
455+ //  func (es *EventSystem) handleTxsEvent(filters filterIndex, ev core.NewTxsEvent) {
456+ //  	for _, f := range filters[PendingTransactionsSubscription] {
457+ //  		f.txs <- ev.Txs
458+ //  	}
459+ //  }
460460
461461func  (es  * EventSystem ) handleChainEvent (filters  filterIndex , ev  core.ChainEvent ) {
462462	for  _ , f  :=  range  filters [BlocksSubscription ] {
@@ -553,7 +553,7 @@ func (es *EventSystem) lightFilterLogs(header *types.Header, addresses []common.
553553func  (es  * EventSystem ) eventLoop () {
554554	// Ensure all subscriptions get cleaned up 
555555	defer  func () {
556- 		es .txsSub .Unsubscribe ()
556+ 		//  es.txsSub.Unsubscribe()
557557		es .logsSub .Unsubscribe ()
558558		es .rmLogsSub .Unsubscribe ()
559559		es .pendingLogsSub .Unsubscribe ()
@@ -567,8 +567,8 @@ func (es *EventSystem) eventLoop() {
567567
568568	for  {
569569		select  {
570- 		case  ev  :=  <- es .txsCh :
571- 			es .handleTxsEvent (index , ev )
570+ 		//  case ev := <-es.txsCh:
571+ 		//  	es.handleTxsEvent(index, ev)
572572		case  ev  :=  <- es .logsCh :
573573			es .handleLogs (index , ev )
574574		case  ev  :=  <- es .rmLogsCh :
0 commit comments