prepare 6.0.0-alpha.11

package.json

@@ -1,6 +1,6 @@
 {
   "name": "ngx-mqtt",
-  "version": "6.0.0-alpha.9",
+  "version": "6.0.0-alpha.11",
   "description": "ngx mqtt client library",
   "main": "bundles/ngx-mqtt.min.js",
   "module": "./src/index.js",

src/mqtt.module.ts

@@ -17,24 +17,19 @@ export const MQTT_SERVICE_OPTIONS: IMqttServiceOptions = {
   path: ''
 };
 
-export const MqttServiceConfig = new InjectionToken<IMqttServiceOptions>('NgxMqttServiceConfig');
-export const MqttClientService = new InjectionToken<MqttClient>('NgxMqttClientService');
+export function mqttServiceFactory() {
+  return new MqttService(MQTT_SERVICE_OPTIONS);
+}
 
 @NgModule()
 export class MqttModule {
-  static forRoot(config: IMqttServiceOptions, client?: MqttClient): ModuleWithProviders {
+  static forRoot(providedService: any = {
+    provide: MqttService,
+    useFactory: mqttServiceFactory
+  }): ModuleWithProviders {
     return {
       ngModule: MqttModule,
-      providers: [
-        {
-          provide: MqttServiceConfig,
-          useValue: config
-        },
-        {
-          provide: MqttClientService,
-          useValue: client
-        }
-      ]
+      providers: [providedService]
     };
   }
 }

src/mqtt.service.ts

@@ -24,16 +24,13 @@ import {
   IPublishOptions
 } from './mqtt.model';
 
-import { MqttModule, MqttServiceConfig, MqttClientService } from './index';
+import { MqttModule } from './index';
 
 /**
  * With an instance of MqttService, you can observe and subscribe to MQTT in multiple places, e.g. in different components,
  * to only subscribe to the broker once per MQTT filter.
  * It also handles proper unsubscription from the broker, if the last observable with a filter is closed.
  */
-@Injectable({
-  providedIn: 'root',
-})
 export class MqttService {
   /** a map of all mqtt observables by filter */
   public observables: { [filter: string]: Observable<IMqttMessage> } = {};
@@ -63,8 +60,8 @@ export class MqttService {
    * @param client an instance of IMqttClient
    */
   constructor(
-    @Inject(MqttServiceConfig) private options: IMqttServiceOptions,
-    @Inject(MqttClientService) private client?: IMqttClient
+    private options: IMqttServiceOptions,
+    private client?: IMqttClient
   ) {
     if (options.connectOnCreate !== false) {
       this.connect({}, client);

tests/mqtt.service.spec.ts

@@ -1,18 +1,5 @@
 import { inject, TestBed } from '@angular/core/testing';
 import { MqttService } from '../src/mqtt.service';
-import { MqttModule } from '../src/mqtt.module';
-
-describe('TestService', () => {
-  beforeEach(() => {
-    TestBed.configureTestingModule({
-      imports: [MqttModule.forRoot({})]
-    });
-  });
-
-  it('should be created', inject([MqttService], (service: MqttService) => {
-    expect(service).toBeTruthy();
-  }));
-});
 
 describe('MqttService', () => {
   it('is defined', () => {