2
2
3
3
namespace BeyondCode \LaravelWebSockets \PubSub \Drivers ;
4
4
5
- use stdClass ;
5
+ use BeyondCode \ LaravelWebSockets \ PubSub \ ReplicationInterface ;
6
6
use React \EventLoop \LoopInterface ;
7
7
use React \Promise \FulfilledPromise ;
8
8
use React \Promise \PromiseInterface ;
9
- use BeyondCode \ LaravelWebSockets \ PubSub \ ReplicationInterface ;
9
+ use stdClass ;
10
10
11
11
class LocalClient implements ReplicationInterface
12
12
{
@@ -23,7 +23,7 @@ class LocalClient implements ReplicationInterface
23
23
* @param LoopInterface $loop
24
24
* @return self
25
25
*/
26
- public function boot (LoopInterface $ loop ) : ReplicationInterface
26
+ public function boot (LoopInterface $ loop ): ReplicationInterface
27
27
{
28
28
return $ this ;
29
29
}
@@ -36,7 +36,7 @@ public function boot(LoopInterface $loop) : ReplicationInterface
36
36
* @param stdClass $payload
37
37
* @return bool
38
38
*/
39
- public function publish (string $ appId , string $ channel , stdClass $ payload ) : bool
39
+ public function publish (string $ appId , string $ channel , stdClass $ payload ): bool
40
40
{
41
41
// Nothing to do, nobody to publish to
42
42
return true ;
@@ -49,7 +49,7 @@ public function publish(string $appId, string $channel, stdClass $payload) : boo
49
49
* @param string $channel
50
50
* @return bool
51
51
*/
52
- public function subscribe (string $ appId , string $ channel ) : bool
52
+ public function subscribe (string $ appId , string $ channel ): bool
53
53
{
54
54
return true ;
55
55
}
@@ -61,7 +61,7 @@ public function subscribe(string $appId, string $channel) : bool
61
61
* @param string $channel
62
62
* @return bool
63
63
*/
64
- public function unsubscribe (string $ appId , string $ channel ) : bool
64
+ public function unsubscribe (string $ appId , string $ channel ): bool
65
65
{
66
66
return true ;
67
67
}
@@ -103,7 +103,7 @@ public function leaveChannel(string $appId, string $channel, string $socketId)
103
103
* @param string $channel
104
104
* @return PromiseInterface
105
105
*/
106
- public function channelMembers (string $ appId , string $ channel ) : PromiseInterface
106
+ public function channelMembers (string $ appId , string $ channel ): PromiseInterface
107
107
{
108
108
$ members = $ this ->channelData ["$ appId: $ channel " ] ?? [];
109
109
@@ -122,7 +122,7 @@ public function channelMembers(string $appId, string $channel) : PromiseInterfac
122
122
* @param array $channelNames
123
123
* @return PromiseInterface
124
124
*/
125
- public function channelMemberCounts (string $ appId , array $ channelNames ) : PromiseInterface
125
+ public function channelMemberCounts (string $ appId , array $ channelNames ): PromiseInterface
126
126
{
127
127
$ results = [];
128
128
0 commit comments