func (es *EventSystem) subscribePendingLogs(crit ethereum.FilterQuery, logs chan []*types.Log) *Subscription {
    sub := &subscription{
        id:        rpc.NewID(),
        typ:       PendingLogsSubscription,
        logsCrit:  crit,