mirror of
https://github.com/pese-git/cherrypick.git
synced 2026-01-23 21:13:35 +00:00
101 lines
2.4 KiB
Dart
101 lines
2.4 KiB
Dart
import 'dart:async';
|
|
import 'package:meta/meta.dart';
|
|
import 'package:dart_di/experimental/scope.dart';
|
|
import 'package:dart_di/experimental/module.dart';
|
|
|
|
class AppModule extends Module {
|
|
bool isMock;
|
|
|
|
AppModule({required this.isMock});
|
|
|
|
@override
|
|
void builder(Scope currentScope) {
|
|
bind<ApiClient>().withName("apiClientMock").toInstance(ApiClientMock());
|
|
bind<ApiClient>().withName("apiClientImpl").toInstance(ApiClientImpl());
|
|
|
|
bind<DataRepository>()
|
|
.withName("networkRepo")
|
|
.toProvide(
|
|
() => NetworkDataRepository(
|
|
currentScope.resolve<ApiClient>(
|
|
named: isMock ? "apiClientMock" : "apiClientImpl",
|
|
),
|
|
),
|
|
)
|
|
.singeltone();
|
|
bind<DataBloc>().toProvide(
|
|
() => DataBloc(
|
|
currentScope.resolve<DataRepository>(named: "networkRepo"),
|
|
),
|
|
);
|
|
}
|
|
}
|
|
|
|
void main() async {
|
|
final scope = openRootScope().installModules([
|
|
AppModule(isMock: false),
|
|
]);
|
|
|
|
final dataBloc = scope.resolve<DataBloc>();
|
|
dataBloc.data.listen((d) => print('Received data: $d'),
|
|
onError: (e) => print('Error: $e'), onDone: () => print('DONE'));
|
|
|
|
await dataBloc.fetchData();
|
|
}
|
|
|
|
class DataBloc {
|
|
final DataRepository _dataRepository;
|
|
|
|
Stream<String> get data => _dataController.stream;
|
|
StreamController<String> _dataController = new StreamController.broadcast();
|
|
|
|
DataBloc(this._dataRepository);
|
|
|
|
Future<void> fetchData() async {
|
|
try {
|
|
_dataController.sink.add(await _dataRepository.getData());
|
|
} catch (e) {
|
|
_dataController.sink.addError(e);
|
|
}
|
|
}
|
|
|
|
void dispose() {
|
|
_dataController.close();
|
|
}
|
|
}
|
|
|
|
abstract class DataRepository {
|
|
Future<String> getData();
|
|
}
|
|
|
|
class NetworkDataRepository implements DataRepository {
|
|
final ApiClient _apiClient;
|
|
final _token = 'token';
|
|
|
|
NetworkDataRepository(this._apiClient);
|
|
|
|
@override
|
|
Future<String> getData() async => await _apiClient.sendRequest(
|
|
url: 'www.google.com', token: _token, requestBody: {'type': 'data'});
|
|
}
|
|
|
|
abstract class ApiClient {
|
|
Future sendRequest({@required String url, String token, Map requestBody});
|
|
}
|
|
|
|
class ApiClientMock implements ApiClient {
|
|
@override
|
|
Future sendRequest(
|
|
{@required String? url, String? token, Map? requestBody}) async {
|
|
return 'Local Data';
|
|
}
|
|
}
|
|
|
|
class ApiClientImpl implements ApiClient {
|
|
@override
|
|
Future sendRequest(
|
|
{@required String? url, String? token, Map? requestBody}) async {
|
|
return 'Network data';
|
|
}
|
|
}
|