$declaration constant

BridgeClassDef const $declaration

Compile-time bridged class declaration for $Stream

Implementation

static const $declaration = BridgeClassDef(
    BridgeClassType($type,
        isAbstract: true, generics: {'T': BridgeGenericParam()}),
    constructors: {
      '': BridgeConstructorDef(
          BridgeFunctionDef(returns: BridgeTypeAnnotation($type))),
      'empty': BridgeConstructorDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])))),
      'value': BridgeConstructorDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'value', BridgeTypeAnnotation(BridgeTypeRef.ref('T')), false)
          ])),
      'error': BridgeConstructorDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter('error',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.object)), false)
          ])),
      'fromFuture': BridgeConstructorDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter('future',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future)), false)
          ])),
      'fromFutures': BridgeConstructorDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'futures',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.iterable, [
                  BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future, [
                    BridgeTypeAnnotation(BridgeTypeRef.ref('T')),
                  ]))
                ])),
                false),
          ])),
      'fromIterable': BridgeConstructorDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'iterable',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.iterable, [
                  BridgeTypeAnnotation(BridgeTypeRef.ref('T')),
                ])),
                false)
          ])),
      'periodic': BridgeConstructorDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'duration',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.duration)),
                false),
            BridgeParameter(
                'computation',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
          ])),
    },
    methods: {
      'asBroadcastStream': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'onListen',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
            BridgeParameter(
                'onCancel',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
          ])),
      'asyncExpand': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'convert',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
      'asyncMap': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'convert',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
      'contains': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.bool))])),
          params: [
            BridgeParameter(
                'needle',
                BridgeTypeAnnotation(BridgeTypeRef.ref('T'), nullable: true),
                false),
          ])),
      'distinct': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'equals',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function),
                    nullable: true),
                true),
          ])),
      'elementAt': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter('index',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.int)), false),
          ])),
      'every': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.bool))])),
          params: [
            BridgeParameter(
                'test',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
      'expand': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'convert',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
      'first': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'test',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
          ])),
      'firstWhere': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'test',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
            BridgeParameter(
                'orElse',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
          ])),
      'fold': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter('initialValue',
                BridgeTypeAnnotation(BridgeTypeRef.ref('T')), false),
            BridgeParameter(
                'combine',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
      'forEach': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.voidType))])),
          params: [
            BridgeParameter(
                'action',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
      'handleError': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'onError',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
            BridgeParameter(
                'test',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
          ])),
      'join': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.string))])),
          params: [
            BridgeParameter('separator',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.string)), true),
          ])),
      'lastWhere': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'test',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
            BridgeParameter(
                'orElse',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
          ])),
      'listen': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.voidType))])),
          params: [
            BridgeParameter(
                'onData',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ],
          namedParams: [
            BridgeParameter(
                'onError',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
            BridgeParameter(
                'onDone',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
            BridgeParameter('cancelOnError',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.bool)), true),
          ])),
      'map': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'convert',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
      'pipe': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.voidType))])),
          params: [
            BridgeParameter('sink',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.object)), false),
          ])),
      'reduce': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'combine',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
      'singleWhere': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'test',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
            BridgeParameter(
                'orElse',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
          ])),
      'skip': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter('count',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.int)), false),
          ])),
      'skipWhile': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'test',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
      'take': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter('count',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.int)), false),
          ])),
      'takeWhile': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'test',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
      'timeout': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'timeLimit',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.duration)),
                false),
            BridgeParameter(
                'onTimeout',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                true),
          ])),
      'toList': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future, [
            BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.list,
                [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          ])),
          params: [
            BridgeParameter('growable',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.bool)), true),
          ])),
      'transform': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter('streamTransformer',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.object)), false),
          ])),
      'where': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.stream,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])),
          params: [
            BridgeParameter(
                'test',
                BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.function)),
                false),
          ])),
    },
    getters: {
      'first': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])))),
      'last': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])))),
      'length': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.int))])))),
      'single': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.future,
              [BridgeTypeAnnotation(BridgeTypeRef.ref('T'))])))),
      'isBroadcast': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.bool)))),
      'isClosed': BridgeMethodDef(BridgeFunctionDef(
          returns: BridgeTypeAnnotation(BridgeTypeRef(CoreTypes.bool)))),
    },
    setters: {},
    fields: {},
    wrap: true);