@@ -13,44 +13,32 @@ class SharedPrefUtil implements LocalDataSource {
13
13
const SharedPrefUtil (this ._rxPrefs);
14
14
15
15
@override
16
- Future <void > removeUserAndToken () async {
17
- bool result;
18
- try {
19
- result = await _rxPrefs.remove (_kUserTokenKey);
20
- } catch (e) {
21
- throw LocalDataSourceException ('Cannot delete user and token' , e);
22
- }
23
-
24
- if (! result) {
25
- throw LocalDataSourceException ('Cannot delete user and token' );
26
- }
27
- }
16
+ Future <void > removeUserAndToken () =>
17
+ _rxPrefs.remove (_kUserTokenKey).onError ((e, s) =>
18
+ throw LocalDataSourceException ('Cannot delete user and token' , e));
28
19
29
20
@override
30
- Future <void > saveUserAndToken (UserAndTokenEntity userAndToken) async {
31
- bool result;
32
- try {
33
- result = await _rxPrefs.write (_kUserTokenKey, userAndToken, _toString);
34
- } catch (e) {
35
- throw LocalDataSourceException ('Cannot save user and token' , e);
36
- }
37
- if (! result) {
38
- throw LocalDataSourceException ('Cannot save user and token' );
39
- }
21
+ Future <void > saveUserAndToken (UserAndTokenEntity userAndToken) {
22
+ return _rxPrefs
23
+ .write <UserAndTokenEntity >(_kUserTokenKey, userAndToken, _toString)
24
+ .onError ((e, s) =>
25
+ throw LocalDataSourceException ('Cannot save user and token' , e));
40
26
}
41
27
42
28
@override
43
- Future <UserAndTokenEntity > get userAndToken =>
44
- _rxPrefs.read (_kUserTokenKey, _toEntity).catchError ((_) => null );
29
+ Future <UserAndTokenEntity > get userAndToken => _rxPrefs
30
+ .read <UserAndTokenEntity >(_kUserTokenKey, _toEntity)
31
+ .catchError ((_) => null );
32
+
33
+ @override
34
+ Stream <UserAndTokenEntity > get userAndToken$ => _rxPrefs
35
+ .observe <UserAndTokenEntity >(_kUserTokenKey, _toEntity)
36
+ .onErrorReturn (null );
45
37
46
38
static UserAndTokenEntity _toEntity (dynamic jsonString) => jsonString == null
47
39
? null
48
40
: UserAndTokenEntity .fromJson (json.decode (jsonString));
49
41
50
42
static String _toString (UserAndTokenEntity entity) =>
51
43
entity == null ? null : jsonEncode (entity);
52
-
53
- @override
54
- Stream <UserAndTokenEntity > get userAndToken$ =>
55
- _rxPrefs.observe (_kUserTokenKey, _toEntity).onErrorReturn (null );
56
44
}
0 commit comments