let counts f e = 
  stream (Counter.of_stream (e /@ f))