Wyatt-FOSS/wyatt-packages
Wyatt-FOSS/wyatt-packages
6
2
Fork 0
Code Issues 20 Pull Requests 3 Actions Packages Projects Releases Activity

fix: use correct behavior subject for stream session
All checks were successful
continuous-integration/drone/pr Build is passing
Details

Browse Source
This commit is contained in:
Hugo Pointcheval 2023-08-16 11:08:53 +02:00
parent 140ca77f56
commit 6f6722f56d
Signed by: hugo
GPG Key ID: 3AAC487E131E00BC
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
packages/wyatt_authentication_bloc/lib/src/data/data_sources/local/authentication_session_data_source_impl.dart
View File

@ -16,6 +16,7 @@
import 'dart:async'; import 'dart:async';
import 'package:rxdart/streams.dart';
import 'package:rxdart/subjects.dart'; import 'package:rxdart/subjects.dart';
import 'package:wyatt_authentication_bloc/src/domain/data_sources/local/authentication_session_data_source.dart'; import 'package:wyatt_authentication_bloc/src/domain/data_sources/local/authentication_session_data_source.dart';
import 'package:wyatt_authentication_bloc/src/domain/entities/auth_session.dart'; import 'package:wyatt_authentication_bloc/src/domain/entities/auth_session.dart';
@ -28,7 +29,7 @@ class AuthenticationSessionDataSourceImpl<Data>
/// {@macro authentication_session_data_source_impl} /// {@macro authentication_session_data_source_impl}
AuthenticationSessionDataSourceImpl(); AuthenticationSessionDataSourceImpl();
final StreamController<AuthenticationSession<Data>> _sessionStream = final BehaviorSubject<AuthenticationSession<Data>> _sessionStream =
BehaviorSubject(); BehaviorSubject();
@override @override
@ -37,9 +38,10 @@ class AuthenticationSessionDataSourceImpl<Data>
} }
@override @override
Future<AuthenticationSession<Data>> currentSession() => sessionStream().last; Future<AuthenticationSession<Data>> currentSession() async =>
_sessionStream.value;
@override @override
Stream<AuthenticationSession<Data>> sessionStream() => Stream<AuthenticationSession<Data>> sessionStream() =>
_sessionStream.stream.asBroadcastStream(); _sessionStream.shareValue();
} }