changesetFeed method

Implementation

@override
ChangeSetEntryFunc changesetFeed(String from) {
  return () async {
    try {
      final next = await _controller.stream.first;
      return next;
    } catch (_) {
      return null;
    }
  };
}