$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,
);