2
2
// Use of this source code is governed by a BSD-style license that can be
3
3
// found in the LICENSE file.
4
4
5
- #include " flutter/shell/platform/common/cpp/client_wrapper/include/flutter/event_channel.h"
6
-
7
5
#include < memory>
8
6
#include < string>
9
7
10
8
#include " flutter/shell/platform/common/cpp/client_wrapper/include/flutter/binary_messenger.h"
9
+ #include " flutter/shell/platform/common/cpp/client_wrapper/include/flutter/event_channel.h"
11
10
#include " flutter/shell/platform/common/cpp/client_wrapper/include/flutter/event_stream_handler_functions.h"
12
11
#include " flutter/shell/platform/common/cpp/client_wrapper/include/flutter/standard_method_codec.h"
13
12
#include " gtest/gtest.h"
@@ -51,25 +50,21 @@ TEST(EventChannelTest, Registration) {
51
50
EventChannel channel (&messenger, channel_name, &codec);
52
51
53
52
bool on_listen_called = false ;
54
- auto handler = std::make_unique<
55
- flutter::StreamHandlerFunctions<flutter::EncodableValue>>(
56
- [&on_listen_called](
57
- const flutter::EncodableValue* arguments,
58
- std::unique_ptr<flutter::EventSink<flutter::EncodableValue>>&& events)
59
- -> std::unique_ptr<StreamHandlerError<flutter::EncodableValue>> {
53
+ auto handler = std::make_unique<StreamHandlerFunctions<>>(
54
+ [&on_listen_called](const EncodableValue* arguments,
55
+ std::unique_ptr<EventSink<>>&& events)
56
+ -> std::unique_ptr<StreamHandlerError<>> {
60
57
on_listen_called = true ;
61
58
return nullptr ;
62
59
},
63
- [](const flutter::EncodableValue* arguments)
64
- -> std::unique_ptr<StreamHandlerError<flutter::EncodableValue>> {
65
- return nullptr ;
66
- });
60
+ [](const EncodableValue* arguments)
61
+ -> std::unique_ptr<StreamHandlerError<>> { return nullptr ; });
67
62
channel.SetStreamHandler (std::move (handler));
68
63
EXPECT_EQ (messenger.last_message_handler_channel (), channel_name);
69
64
EXPECT_NE (messenger.last_message_handler (), nullptr );
70
65
71
66
// Send dummy listen message.
72
- MethodCall<flutter::EncodableValue > call (" listen" , nullptr );
67
+ MethodCall<> call (" listen" , nullptr );
73
68
auto message = codec.EncodeMethodCall (call);
74
69
messenger.last_message_handler ()(
75
70
message->data (), message->size (),
@@ -86,17 +81,11 @@ TEST(EventChannelTest, Unregistration) {
86
81
const StandardMethodCodec& codec = StandardMethodCodec::GetInstance ();
87
82
EventChannel channel (&messenger, channel_name, &codec);
88
83
89
- auto handler = std::make_unique<
90
- flutter::StreamHandlerFunctions<flutter::EncodableValue>>(
91
- [](const flutter::EncodableValue* arguments,
92
- std::unique_ptr<flutter::EventSink<flutter::EncodableValue>>&& events)
93
- -> std::unique_ptr<StreamHandlerError<flutter::EncodableValue>> {
94
- return nullptr ;
95
- },
96
- [](const flutter::EncodableValue* arguments)
97
- -> std::unique_ptr<StreamHandlerError<flutter::EncodableValue>> {
98
- return nullptr ;
99
- });
84
+ auto handler = std::make_unique<StreamHandlerFunctions<>>(
85
+ [](const EncodableValue* arguments, std::unique_ptr<EventSink<>>&& events)
86
+ -> std::unique_ptr<StreamHandlerError<>> { return nullptr ; },
87
+ [](const EncodableValue* arguments)
88
+ -> std::unique_ptr<StreamHandlerError<>> { return nullptr ; });
100
89
channel.SetStreamHandler (std::move (handler));
101
90
EXPECT_EQ (messenger.last_message_handler_channel (), channel_name);
102
91
EXPECT_NE (messenger.last_message_handler (), nullptr );
@@ -115,17 +104,15 @@ TEST(EventChannelTest, Cancel) {
115
104
116
105
bool on_listen_called = false ;
117
106
bool on_cancel_called = false ;
118
- auto handler = std::make_unique<
119
- flutter::StreamHandlerFunctions<flutter::EncodableValue>>(
120
- [&on_listen_called](
121
- const flutter::EncodableValue* arguments,
122
- std::unique_ptr<flutter::EventSink<flutter::EncodableValue>>&& events)
123
- -> std::unique_ptr<StreamHandlerError<flutter::EncodableValue>> {
107
+ auto handler = std::make_unique<StreamHandlerFunctions<>>(
108
+ [&on_listen_called](const EncodableValue* arguments,
109
+ std::unique_ptr<EventSink<>>&& events)
110
+ -> std::unique_ptr<StreamHandlerError<>> {
124
111
on_listen_called = true ;
125
112
return nullptr ;
126
113
},
127
- [&on_cancel_called](const flutter:: EncodableValue* arguments)
128
- -> std::unique_ptr<StreamHandlerError<flutter::EncodableValue >> {
114
+ [&on_cancel_called](const EncodableValue* arguments)
115
+ -> std::unique_ptr<StreamHandlerError<>> {
129
116
on_cancel_called = true ;
130
117
return nullptr ;
131
118
});
@@ -134,15 +121,15 @@ TEST(EventChannelTest, Cancel) {
134
121
EXPECT_NE (messenger.last_message_handler (), nullptr );
135
122
136
123
// Send dummy listen message.
137
- MethodCall<flutter::EncodableValue > call_listen (" listen" , nullptr );
124
+ MethodCall<> call_listen (" listen" , nullptr );
138
125
auto message = codec.EncodeMethodCall (call_listen);
139
126
messenger.last_message_handler ()(
140
127
message->data (), message->size (),
141
128
[](const uint8_t * reply, const size_t reply_size) {});
142
129
EXPECT_EQ (on_listen_called, true );
143
130
144
131
// Send dummy cancel message.
145
- MethodCall<flutter::EncodableValue > call_cancel (" cancel" , nullptr );
132
+ MethodCall<> call_cancel (" cancel" , nullptr );
146
133
message = codec.EncodeMethodCall (call_cancel);
147
134
messenger.last_message_handler ()(
148
135
message->data (), message->size (),
@@ -164,17 +151,15 @@ TEST(EventChannelTest, ReRegistration) {
164
151
165
152
bool on_listen_called = false ;
166
153
bool on_cancel_called = false ;
167
- auto handler = std::make_unique<
168
- flutter::StreamHandlerFunctions<flutter::EncodableValue>>(
169
- [&on_listen_called](
170
- const flutter::EncodableValue* arguments,
171
- std::unique_ptr<flutter::EventSink<flutter::EncodableValue>>&& events)
172
- -> std::unique_ptr<StreamHandlerError<flutter::EncodableValue>> {
154
+ auto handler = std::make_unique<StreamHandlerFunctions<>>(
155
+ [&on_listen_called](const EncodableValue* arguments,
156
+ std::unique_ptr<EventSink<>>&& events)
157
+ -> std::unique_ptr<StreamHandlerError<>> {
173
158
on_listen_called = true ;
174
159
return nullptr ;
175
160
},
176
- [&on_cancel_called](const flutter:: EncodableValue* arguments)
177
- -> std::unique_ptr<StreamHandlerError<flutter::EncodableValue >> {
161
+ [&on_cancel_called](const EncodableValue* arguments)
162
+ -> std::unique_ptr<StreamHandlerError<>> {
178
163
on_cancel_called = true ;
179
164
return nullptr ;
180
165
});
@@ -183,7 +168,7 @@ TEST(EventChannelTest, ReRegistration) {
183
168
EXPECT_NE (messenger.last_message_handler (), nullptr );
184
169
185
170
// Send dummy listen message.
186
- MethodCall<flutter::EncodableValue > call (" listen" , nullptr );
171
+ MethodCall<> call (" listen" , nullptr );
187
172
auto message = codec.EncodeMethodCall (call);
188
173
messenger.last_message_handler ()(
189
174
message->data (), message->size (),
0 commit comments