@@ -62,4 +62,65 @@ void main() {
6262 );
6363 });
6464 });
65+
66+ group ('DefaultLogger<String, int>' , () {
67+ final logger = DefaultLogger <String , int >();
68+
69+ test ('KeysChangedEvent' , () {
70+ const pairs = [
71+ KeyAndValue ('key1' , 'value1' ),
72+ KeyAndValue ('key2' , 2 ),
73+ ];
74+
75+ expect (
76+ () => logger.log (KeysChangedEvent (pairs)),
77+ prints ([
78+ ' ↓ Key changes' ,
79+ " → { 'key1': value1 }" ,
80+ " → { 'key2': 2 }\n " ,
81+ ].join ('\n ' )),
82+ );
83+ ;
84+ });
85+
86+ test ('OnDataStreamEvent' , () {
87+ const pair = KeyAndValue ('key1' , 'value1' );
88+ expect (
89+ () => logger.log (OnDataStreamEvent (pair)),
90+ prints (" → Stream emits data: { 'key1': value1 }\n " ),
91+ );
92+ });
93+
94+ test ('OnErrorStreamEvent' , () {
95+ final stackTrace = StackTrace .current;
96+ final exception = Exception ();
97+ expect (
98+ () => logger
99+ .log (OnErrorStreamEvent (RxStorageError (exception, stackTrace))),
100+ prints (' → Stream emits error: $exception , $stackTrace \n ' ),
101+ );
102+ });
103+
104+ test ('ReadValueSuccessEvent' , () {
105+ const type = String ;
106+ const key = 'key' ;
107+ const value = 'value' ;
108+ expect (
109+ () =>
110+ logger.log (ReadValueSuccessEvent (KeyAndValue (key, value), type, 0 )),
111+ prints (" → Read: type=String, key='key', options=0 → value\n " ),
112+ );
113+ });
114+
115+ test ('WriteSuccessEvent' , () {
116+ const type = String ;
117+ const key = 'key' ;
118+ const value = 'value' ;
119+ expect (
120+ () => logger.log (WriteSuccessEvent (KeyAndValue (key, value), type, 0 )),
121+ prints (
122+ " ← Write: key='key', value=value, type=String, options=0 → success\n " ),
123+ );
124+ });
125+ });
65126}
0 commit comments