pull method

void pull()

Implementation

void pull() {
  _subject.add(_mapper(_upstream.latest));
}