Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history
  • Loading branch information
tabuna committed Mar 12, 2024
1 parent 5f1086c commit 833fa07
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 180 deletions.
130 changes: 0 additions & 130 deletions app/Queue.php

This file was deleted.

50 changes: 0 additions & 50 deletions tests/Unit/ExampleTest.php
Original file line number Diff line number Diff line change
Expand Up @@ -14,54 +14,4 @@ public function test_that_true_is_true(): void
{
$this->assertTrue(true);
}

public function testMessageCanBeDispatchedAndReceived()
{
// Создание экземпляра класса Queue
$queue = new Queue('test');

// Создание фиктивного действия при получении сообщения
$action = function (string $message, int $type) {
$this->assertEquals('Hello, world!', $message);
$this->assertEquals(1, $type);
};

// Отправка сообщения в очередь
$queue->dispatch('Hello, world!');

// Получение сообщения из очереди
$queue->listen($action);
}

public function testMessageCanBeDispatchedAndReceived2()
{
// Создание экземпляра класса Queue
$queue = new Queue('test');
// $queue->clear();

// Создание фиктивного действия при получении сообщения
$action = function () {
$this->assertTrue(true);
};

// Отправка сообщения в очередь
$queue->dispatchClosure($action);

// Получение сообщения из очереди
$queue->listenClosure($action);
}

public function testFailedMessageReceive()
{
// Создание экземпляра класса Queue
$queue = new Queue('test');

// Создание фиктивного действия в случае ошибки при получении сообщения
$failedAction = function ($error) {
$this->fail('Failed to receive a message: '.$error);
};

// Получение сообщения из очереди с указанием несуществующего типа сообщения
// $queue->listen(function () {}, $failedAction);
}
}

0 comments on commit 833fa07

Please sign in to comment.