Skip to content
This repository was archived by the owner on Feb 7, 2024. It is now read-only.

Commit 4b484aa

Browse files
committed
Fixed store
1 parent 53a6d0f commit 4b484aa

File tree

1 file changed

+9
-2
lines changed

1 file changed

+9
-2
lines changed

src/ChannelManagers/LocalChannelManager.php

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,13 @@ class LocalChannelManager implements ChannelManager
4646
*/
4747
protected $acceptsNewConnections = true;
4848

49+
/**
50+
* The ArrayStore instance of locks.
51+
*
52+
* @var \Illuminate\Cache\ArrayStore
53+
*/
54+
protected $store;
55+
4956
/**
5057
* The lock name to use on Array to avoid multiple
5158
* actions that might lead to multiple processings.
@@ -63,7 +70,7 @@ class LocalChannelManager implements ChannelManager
6370
*/
6471
public function __construct(LoopInterface $loop, $factoryClass = null)
6572
{
66-
//
73+
$this->store = new ArrayStore;
6774
}
6875

6976
/**
@@ -509,6 +516,6 @@ protected function getChannelClassName(string $channelName): string
509516
*/
510517
protected function lock()
511518
{
512-
return new ArrayLock(new ArrayStore, static::$lockName, 0);
519+
return new ArrayLock($this->store, static::$lockName, 0);
513520
}
514521
}

0 commit comments

Comments
 (0)